package com.lzh.others.Thread;

import java.util.concurrent.ForkJoinPool;

/**
 * @Description: ForkJoinPool + parallelStream实现并行快速处理数据流
 * execute(ForkJoinTask) 异步执行tasks，无返回值
 * invoke(ForkJoinTask) 有Join会使主线程挂起等待task的结果, tasks会被同步到主进程
 * submit(ForkJoinTask) 异步执行，直接返回task对象，可通过task.get/join 阻塞主线程然后将结果同步到主线程
 * @Author: LiuZiHao
 * @Date: 2022/7/8 10:51
 */
public class ForkParallel {
    public static void main(String[] args) {
        ForkJoinPool forkJoinPool = new ForkJoinPool(10);
//        forkJoinPool.invoke();
    }
}
